package hanlen.mq.starter.core;

import hanlen.mq.starter.bean.MessageWrap;

/**
 * archives-service
 *
 * @author MrYe
 * @Description
 * @date 2021-10-23 16:02
 */
public interface RedisQueueInterceptor {

    /**
     * 统一拦截
     *
     * @param queue       队列名
     * @param backlogNums 积压消息数
     * @param msg         消息
     * @return body消息
     */
    <T> T preHandle(String queue, Integer backlogNums, MessageWrap msg);

}
